package com.duoec.dw.lineage.service.analyser.statement;

import com.duoec.dw.lineage.dto.statement.SqoopStatement;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author xuwenzhen
 */
@Service
public class ExcludeSqoopStatementAnalyser extends BaseSqoopStatementAnalyser<SqoopStatement> {

    public static final String STR_JDBC_VERTICA = "jdbc:vertica";
    public static final String STR_HCATALOG = "hcatalog";

    /**
     * 检查当前行是否需要当前分析器处理
     *
     * @param line 当前行
     * @return true，则会使用analyse方法解析
     */
    @Override
    public boolean check(String line) {
        String lowerCaseStr = line.toLowerCase();
//        if (lowerCaseStr.contains(STR_JDBC_VERTICA)) {
//            throw new UnsupportedDbException("不支持DB：vertica");
//        }
//        if (lowerCaseStr.contains(STR_HCATALOG)) {
//            throw new UnsupportedDbException("不支持DB：hcatalog");
//        }
        return false;
    }

    /**
     * 解析脚本，并返回当前的语句
     *
     * @param lines 所有行
     * @param index 开始行，0开始
     * @return 当前语句
     */
    @Override
    public SqoopStatement analyse(List<String> lines, int index) {
        return null;
    }
}
